package com.riven.bilibilidemo.rx;

import rx.Observer;


public abstract class MyObserver<T> implements Observer<T> {
    @Override
    public void onError(Throwable e) {

    }

    @Override
    public void onNext(T t) {
        onNextTo(t);
    }

    @Override
    public void onCompleted() {

    }
    protected  abstract  void onNextTo(T t);
}
